package com.xiangxiao.rpan.data.channel;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @auther xiangxiao
 * @email 573768011@qq.com
 * @data 2024/5/30 17:05
 */
public interface GreetingsStreams {
  String INPUT = "greetings-in";
  String OUTPUT = "greetings-out";

  /**
   * input
   * @return SubscribableChannel
   */
  @Input(INPUT)
  SubscribableChannel inboundGreetings();

  /**
   * output
   * @return MessageChannel
   */
  @Output(OUTPUT)
  MessageChannel outboundGreetings();
}
